package com.lp.model.constants;

/**
 * RabbitMQ 所需常量
 */
public class MQConstants {

    // 文章直接交换机
    public static final String ARTICLE_EXCHANGE_DIRECT = "article.exchange.direct";
    // 文章统计信息异步到 redis 的队列
    public static final String ARTICLE_STAT_QUEUE = "article.stat.queue";
    // 文章阅读量异步到 mysql 的队列
    public static final String ARTICLE_VISITS_QUEUE = "article.visits.queue";
    // 文章点赞状态异步 redis 和 mysql 的队列
    public static final String ARTICLE_LIKE_QUEUE = "article.like.queue";
    // 文章收藏状态异步 redis 和 mysql 的队列
    public static final String ARTICLE_COLLECT_QUEUE = "article.collect.queue";

    // 消息和状态交换机
    public static final String MSG_AND_STATE_EXCHANGE_DIRECT = "msg.and.state.exchange.direct";
    // 文章点赞消息异步到 redis
    public static final String LIKE_MSG_SYN_REDIS_QUEUE = "like.msg.syn.redis.queue";
    // 文章点赞消息状态异步到 mysql
    public static final String LIKE_MSG_STATE_SYN_MYSQL_QUEUE = "like.msg.state.syn.mysql.queue";


    //评论交换机
    public static final String COMMENT_EXCHANGE_DIRECT = "comment.exchange.direct";
    // 评论量增加或减少异步 redis 和 mysql
    public static final String COMMENT_INCR_OR_DECR_QUEUE = "comment.add.or.decr.queue";

    // 用户直接交换机
    public static final String USER_EXCHANGE_DIRECT = "user.exchange.direct";
    // 关注/取关 消息队列
    public static final String USER_FOLLOW_QUEUE = "user.follow.queue";

    // 同步 es 交换机
    public static final String ES_EXCHANGE_DIRECT = "es.exchange.direct";
    // 文章信息同步到 es
    public static final String ES_ARTICLE_INSERT_QUEUE = "es.article.insert.queue";
    // 文章删除同步 es
    public static final String ES_ARTICLE_DEL_QUEUE = "es.article.del.queue";
    // 文章修改同步到 es
    public static final String ES_ARTICLE_UPDATE_QUEUE = "es.article.update.queue";
    // 用户基本信息修改
    public static final String ES_USER_UPDATE_QUEUE = "es.user.update.queue";


}

